package com.gandong8.trace.tool.consumer.rocketmq.custom;

import com.gandong8.trace.tool.consumer.rocketmq.AbstractRocketMqListener;
import lombok.extern.slf4j.Slf4j;


@Slf4j
public class TopicOneListener extends AbstractRocketMqListener<String> {
    @Override
    protected void execute(String message) {
        System.out.println("topic1：" + message);
    }


}
